package com.wujian.love.mapper;

import com.wujian.love.domin.RocketMessage;

import java.util.List;

/**
 * rocketmq消息记录 数据层
 * 
 * @author cdw
 * @date 2020-07-08
 */
public interface RocketMessageMapper 
{
	/**
     * 查询rocketmq消息记录信息
     * 
     * @param id rocketmq消息记录ID
     * @return rocketmq消息记录信息
     */
	public RocketMessage selectRocketMessageById(Integer id);
	
	/**
     * 查询rocketmq消息记录列表
     * 
     * @param rocketMessage rocketmq消息记录信息
     * @return rocketmq消息记录集合
     */
	public List<RocketMessage> selectRocketMessageList(RocketMessage rocketMessage);
	
	/**
     * 新增rocketmq消息记录
     * 
     * @param rocketMessage rocketmq消息记录信息
     * @return 结果
     */
	public int insertRocketMessage(RocketMessage rocketMessage);
	
	/**
     * 修改rocketmq消息记录
     * 
     * @param rocketMessage rocketmq消息记录信息
     * @return 结果
     */
	public int updateRocketMessage(RocketMessage rocketMessage);
	
	/**
     * 删除rocketmq消息记录
     * 
     * @param id rocketmq消息记录ID
     * @return 结果
     */
	public int deleteRocketMessageById(Integer id);
	
	/**
     * 批量删除rocketmq消息记录
     * 
     * @param ids 需要删除的数据ID
     * @return 结果
     */
	public int deleteRocketMessageByIds(String[] ids);

	/**
	 * @Author WuJian
	 * @Description //根据keys修改消息消费状态
	 * @Date 9:39 2020/7/9
	 * @Param [keys]
	 * @return void
	 **/
    int updateRocketMessageByKeys(String keys);

	/**
	 * @Author WuJian
	 * @Description //根据keys 查询消息
	 * @Date 9:39 2020/7/9
	 * @Param [keys]
	 * @return void
	 **/
	RocketMessage selectRocketMessageByKeys(String keys);
}